package com.tarena.test.stream.receiver.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface StreamInputChannelSource {
    String IN_PUT="stream-test-input";
    @Input(IN_PUT)
    SubscribableChannel input();
}
